package com.mingshine.cloud.config;

import org.springframework.amqp.core.Queue;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;


@Configuration
public class QueueConfig {
    //广播队列1,2：因为广播指的是广播到所有绑定到此路由的对列
    public static final String QUEUE_UPDATE_DEVICE_WORKINFO = "queue_update_device_workinfo";

    /***
     * 广播队列 1
     * @return
     */
    @Bean
    public Queue queueDeviceWorkInfo() {
        /**
         durable="true" 持久化 rabbitmq重启的时候不需要创建新的队列
         exclusive  表示该消息队列是否只在当前connection生效,默认是false
         auto-delete 表示消息队列没有在使用时将被自动删除 默认是false
         */
        return new Queue(QUEUE_UPDATE_DEVICE_WORKINFO, true, false, false);
    }


}